package cn.com.greatwall.kafka.service;

import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ExecutionException;

import org.springframework.security.core.userdetails.UserDetails;

import cn.com.greatwall.kafka.service.dto.ClusterDto;

/**
 * @Author herw
 * @Time 2021-05-10 15:13:40
 * @Version 1.0
 * @Description: TODO(用一句话描述该文件做什么)
 */
public interface MonitorService {
    /**
    * 查询topic
    * @param criteria 条件参数
    * @return List<TopicDto>
    */
    Map<String,Object> getTopicList(List<ClusterDto> clusterDtos, UserDetails user);
    
    /**
     * 获取集群所有topic
     * @return
     */
    Set<String> getTopicList(String clusterId) throws InterruptedException, ExecutionException;
}
